/**
 * 模型
 */
const mysql = require('mysql')

module.exports = class Model {
    /**
     * 连接对象
     */
    static conn = null

    /**
     * 连接数据库
     */
    static connection() {
        Model.conn = mysql.createConnection({
            host: 'localhost',
            user: 'root',
            password: 'ok',
            database: 'blog1'
        })
        Model.conn.connect(err => {
            if (err) {
                console.log(`数据库连接失败：${err.message}`)
            }
        })
    }

    /**
     * 关闭数据库
     */
    static end() {
        if (null != Model.conn) {
            Model.conn.end()
        }
    }

    /**
     * 通用查询
     */
    static query(sql, params = []) {
        return new Promise((resolve, reject) => {
            this.connection()
            Model.conn.query(sql, params, (err, results) => {
                if (err) {
                    reject(err)
                } else {
                    resolve(results)
                }
            })
            this.end()
        })
    }
    // 通用的增加
    static add(sql,params=[]){
        return new Promise((resolve,reject)=>{
            this.connection();
            Model.conn.query(sql,params,(err,result)=>{
                if(err){
                    reject(err)
                }else{
                resolve(result)
               
                }
            })
            this.end()
        })
    }
}